# !/usr/bin/env python
# -*- coding:utf-8 -*-
# @FileName  :main.py
# @Time      :2022/5/27 16:49
# @Author    :张志坤

# celery
from celery import Celery

# include=[]  # 元素是任务
app = Celery("worker", broker="redis://127.0.0.1:6379/5", backend="redis://127.0.0.1:6379/6")
# 加载配置文件
# app.config_from_object("common.celery_tasks")
# 要执行的任务函数所在文件
# 自动发现任务
app.autodiscover_tasks(['common.tasks.send_code'])

